import sqlite3


def sellBill(data):
    print(5555, data)
    # 连接到SQLite数据库（如果数据库不存在，则会自动创建）
    conn = sqlite3.connect(r'instance/site.db')

    # 创建一个游标对象
    cur = conn.cursor()
    # 使用execute()方法执行SQL，这里我们创建一个名为sellBill的表
    cur.execute('''
        CREATE TABLE IF NOT EXISTS sellBill (
            occurAge  TEXT NOT NULL,
            numbers TEXT PRIMARY KEY,
            client TEXT NOT NULL,
            oneText TEXT NOT NULL,
            univalence REAL NOT NULL,
            sums REAL NOT NULL,
            note TEXT
        )
        ''')
    # 插入一条数据到sellBill表中
    ppp = data
    if ppp:
        cur.execute('''
            INSERT INTO sellBill (occurAge,numbers,client,oneText,univalence,sums,note) VALUES (?,?,?,?,?,?,?)
            ''', (ppp.get('记录的创建日期'),
                  ppp.get('交货单号'), ppp.get('售达方名称'), ppp.get('销售订单项目短文本'), ppp.get('结算含税金额（元）')
                                      , ppp.get('交货数量（吨）'), ppp.get('备注'),))

    # # 使用参数化查询防止SQL注入 {'交货单号': 2020003027, '售达方名称': '上海莫道贸易有限公司', '销售订单项目短文本': '香雪手抓饼用小麦粉168#-25kg', '交货数量（吨）': 28.7,
    # # '结算含税金额（元）': 100450.0, '备注': '苏H5766L，王兆军18932302203身份证320821197104151930，按照三全的要求和批检报名，随车携带检测报告，订单号，5500826007'}

    # 提交当前事务
    conn.commit()

    # 关闭与数据库的连接
    conn.close()


def get_Bill(data):
    print(5555, data)
    # 连接到SQLite数据库（如果数据库不存在，则会自动创建）
    conn = sqlite3.connect(r'instance/site.db')

    # 创建一个游标对象
    c = conn.cursor()
    # 查询一条数据到sellBill表中
    ppp = data
    # 查询所有用户
    c.execute("SELECT * FROM sellBill")

    # 获取所有结果
    rows = c.fetchall()
    for row in rows:
        print(row)

    # 关闭与数据库的连接
    conn.close()
    return rows


if __name__ == '__main__':
    # sellBill(data=None)
    get_Bill(data=None)

print("Table created successfully.")
